package org.rency.crawler.integration.kafka;

import org.springframework.kafka.annotation.KafkaListener;

/**
 * 描述: ${TODO}<br>
 * 最近修改时间:2017/11/29 17:35<br>
 *
 * @author CaiyuRen
 * @version V1.0
 * @since 2017/11/29 17:35
 */
//@Component
public class MessageListener {

  @KafkaListener(id = "fetchQueue",topics = "org.rency.crawler.fetch.queue")
  public void listener(String fetchQueue){
    System.out.println(fetchQueue);
  }
}
